a372354a3cb65a4de88a1bdc4413940c6cec32f0,app-fabric/src/main/java/org/apache/hadoop/mapred/LocalJobRunnerWithFix.java,Job,statusUpdate,#TaskAttemptID#TaskStatus#,535
Before Change
status.setMapProgress(partialProgress / numTasks);
} else {
reduceCounters = taskStatus.getCounters();
status.setReduceProgress(taskStatus.getProgress());
}
// ignore phase
After Change
int reduceTaskIndex = taskId.getTaskID().getId();
float numTasks = (float) this.numReduceTasks;
partialReduceProgress[reduceTaskIndex] = taskStatus.getProgress();
reduceCounters[reduceTaskIndex] = taskStatus.getCounters();
float partialProgress = 0.0f;